Skip to content

Commit 9d573ef

Browse files
committed
WIP
1 parent baa270b commit 9d573ef

File tree

87 files changed

+4776
-1712
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

87 files changed

+4776
-1712
lines changed

Rewrite/Rewrite.Rpc/DeltaSerializer.cs

Lines changed: 0 additions & 168 deletions
This file was deleted.

Rewrite/Rewrite.Rpc/IRpcCodec.cs

Lines changed: 44 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -1,44 +1,44 @@
1-
/*
2-
* Copyright 2025 the original author or authors.
3-
*
4-
* Licensed under the Apache License, Version 2.0 (the "License");
5-
* you may not use this file except in compliance with the License.
6-
* You may obtain a copy of the License at
7-
*
8-
* https://www.apache.org/licenses/LICENSE-2.0
9-
*
10-
* Unless required by applicable law or agreed to in writing, software
11-
* distributed under the License is distributed on an "AS IS" BASIS,
12-
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13-
* See the License for the specific language governing permissions and
14-
* limitations under the License.
15-
*/
16-
17-
namespace Rewrite.Rpc;
18-
19-
/// <summary>
20-
/// A codec decomposes a value into multiple RPC <see cref="RpcObjectData"/> events, and
21-
/// on the receiving side reconstitutes the value from those events.
22-
/// </summary>
23-
/// <typeparam name="T">The type of the value being sent and received.</typeparam>
24-
public interface IRpcCodec<T>
25-
{
26-
/// <summary>
27-
/// When the value has been determined to have been changed, this method is called
28-
/// to send the values that comprise it.
29-
/// </summary>
30-
/// <param name="after">The value that has been either added or changed.</param>
31-
/// <param name="q">The send queue that is collecting <see cref="RpcObjectData"/> to send.</param>
32-
Task RpcSend(T after, RpcSendQueue q);
33-
34-
/// <summary>
35-
/// When the value has been determined to have been changed, this method is called
36-
/// to receive the values that comprise it.
37-
/// </summary>
38-
/// <param name="before">The value that has been either added or changed. In the case where it is added,
39-
/// the before state will be non-null, but will be an initialized object with
40-
/// all null fields that are expecting to be populated by this method.</param>
41-
/// <param name="q">The queue that is receiving <see cref="RpcObjectData"/> from a remote.</param>
42-
/// <returns>The received value.</returns>
43-
Task<T> RpcReceive(T before, RpcReceiveQueue q);
44-
}
1+
// /*
2+
// * Copyright 2025 the original author or authors.
3+
// *
4+
// * Licensed under the Apache License, Version 2.0 (the "License");
5+
// * you may not use this file except in compliance with the License.
6+
// * You may obtain a copy of the License at
7+
// *
8+
// * https://www.apache.org/licenses/LICENSE-2.0
9+
// *
10+
// * Unless required by applicable law or agreed to in writing, software
11+
// * distributed under the License is distributed on an "AS IS" BASIS,
12+
// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
// * See the License for the specific language governing permissions and
14+
// * limitations under the License.
15+
// */
16+
//
17+
// namespace Rewrite.Rpc;
18+
//
19+
// /// <summary>
20+
// /// A codec decomposes a value into multiple RPC <see cref="RpcObjectData"/> events, and
21+
// /// on the receiving side reconstitutes the value from those events.
22+
// /// </summary>
23+
// /// <typeparam name="T">The type of the value being sent and received.</typeparam>
24+
// public interface IRpcCodec<T>
25+
// {
26+
// /// <summary>
27+
// /// When the value has been determined to have been changed, this method is called
28+
// /// to send the values that comprise it.
29+
// /// </summary>
30+
// /// <param name="after">The value that has been either added or changed.</param>
31+
// /// <param name="q">The send queue that is collecting <see cref="RpcObjectData"/> to send.</param>
32+
// Task RpcSend(T after, RpcSendQueue q);
33+
//
34+
// /// <summary>
35+
// /// When the value has been determined to have been changed, this method is called
36+
// /// to receive the values that comprise it.
37+
// /// </summary>
38+
// /// <param name="before">The value that has been either added or changed. In the case where it is added,
39+
// /// the before state will be non-null, but will be an initialized object with
40+
// /// all null fields that are expecting to be populated by this method.</param>
41+
// /// <param name="q">The queue that is receiving <see cref="RpcObjectData"/> from a remote.</param>
42+
// /// <returns>The received value.</returns>
43+
// Task<T> RpcReceive(T before, RpcReceiveQueue q);
44+
// }

0 commit comments

Comments
 (0)