rocketmq-protocol 1.0.0

Runtime-neutral RocketMQ wire protocol contracts
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

error[E0277]: the trait bound `ExternalSink: header_codec::private::Sealed` is not satisfied
  --> tests/ui/request_header_codec_runtime/fail/external_sink.rs:20:21
   |
20 | impl EncodeSink for ExternalSink {
   |                     ^^^^^^^^^^^^ unsatisfied trait bound
   |
help: the trait `header_codec::private::Sealed` is not implemented for `ExternalSink`
  --> tests/ui/request_header_codec_runtime/fail/external_sink.rs:18:1
   |
18 | struct ExternalSink;
   | ^^^^^^^^^^^^^^^^^^^
   = help: the following other types implement trait `header_codec::private::Sealed`:
             BinarySink<'_>
             JsonSink<'_>
             MapSink<'_>
             bool
             i32
             i64
             rocketmq_model::boundary_type::BoundaryType
             std::string::String
           and $N others
note: required by a bound in `EncodeSink`
  --> src/protocol/header_codec/sink.rs
   |
   | pub trait EncodeSink: Sealed {
   |                       ^^^^^^ required by this bound in `EncodeSink`
   = note: `EncodeSink` is a "sealed trait", because to implement it you also need to implement `rocketmq_protocol::protocol::header_codec::private::Sealed`, which is not accessible; this is usually done to force you to use one of the provided types that already implement it
   = help: the following types implement the trait:
             rocketmq_protocol::protocol::header_codec::MapSink<'_>
             rocketmq_protocol::protocol::header_codec::JsonSink<'_>
             rocketmq_protocol::protocol::header_codec::BinarySink<'_>
             rocketmq_protocol::__request_header_codec::CheetahString
             std::string::String
             bool
             i32
             i64
           and $N others