xiazuojie

Results 10 comments of xiazuojie

You can emulate this by pausing (through debug) the receiver process while the sender continues writing messages. The sender will be out of memory eventually. It's a pitfall warned by...

On second thoughts, it's not a good design to differentiate between pass-through and byte[] with DaprObjectSerializer. Pass-through should be specified in APIs of [DaprClient](https://github.com/dapr/java-sdk/blob/master/sdk/src/main/java/io/dapr/client/DaprClient.java).

> This issue is an example of why the DefaultObjectSerializer is just for examples and getting started but not for production use. If you need byte[] to be handled as-is,...

To support serialization negotiation (https://github.com/dapr/dapr/issues/2905), I suggest the DaprObjectSerializer interface to be changed to: ```java public interface DaprObjectSerializer { /** * Serializes the given object as byte[]. * * @param...

> We can accomplish the same with the current interface. getContentType() can be used to determine if the data can be deserialized too. Plus, we still need to know which...

> @xiazuojie Can the same be accomplished with a different DaprClient instance per serializer? The original design was that for apps that need multiple serializers, they could simply instantiate a...

@artursouza Have you found alternative solution to support serialization negotiation?

Both serialization and deserialization needs to consider serialization-type. ```java public interface DaprObjectSerializer { // Serialize according to specified mimeType byte[] serialize(Object o, MimeType mimeType) throws IOException; // Deserialize according to...

> That interface is too specific for the multi-serialization solution - which is one implementation of the interface. Yes, that's the reason why I suggest the following interface in the...

"Messages are added to sendProcessor so they are hitting network, never dropped." This existing implementation has a serious OOM issue as described https://github.com/reactor/reactor-netty/issues/881 There needs to be some way to...