Applications need a higher-level and richer, functional API to compose async logic — similar to the Java 8 Stream API but not only for collections. This is the role that reactive libraries play. Reactor is the Jackson2Decoder works as follows: • Jackson’s asynchronous, non-blocking parser is used to aggregate a stream of byte chunks into TokenBuffer's each representing a JSON object. • Each TokenBuffer is passed a multi-value publisher with a streaming media type such as application/x-ndjson or application/stream+x-jackson-smile, encode, write, and flush each value individually using a line-delimited JSON format

other byte stream transports, using one of the following interaction models: • Request-Response — send one message and receive one back. • Request-Stream — send one message and receive a stream of messages protocol: • Reactive Streams semantics across network boundary — for streaming requests such as Request-Stream and Channel, back pressure signals travel between requester and responder, allowing a requester established, both sides may initiate a request through one of the frames REQUEST_RESPONSE, REQUEST_STREAM, REQUEST_CHANNEL, or REQUEST_FNF. Each of those frames carries one message from the requester to

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 338 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate

▶ 流（Stream） Java 中把不同的数据源与程序间的数据传输都抽象表述为 流，java.io 包中定义了多种 I/O 流类型实现数据 I/O 功能。 大纲 Java I/O 原理 基础 I/O 流 常用 I/O 流类型 I/O 应用 Java I/O 流的分类 O 按照数据流动的方向 Java 流可分为输入流（Input Stream）和输出流（Output Stream）。 ▶ I/O 原理 基础 I/O 流 常用 I/O 流类型 I/O 应用 Java I/O 流的分类 O 根据数据流所关联的是数据源还是其他数据流 可分为节点流（Node Stream）和处理流（Processing Stream）。 ▶ 节点流直接连接到数据源； ▶ 处理流是对一个已存在的流的连接和封装，通过所封装的流 的功能调用实现增强的数据读/写功能，处理流并不直接连 到数据源。 Howareyou Java I/O 原理 基础 I/O 流 常用 I/O 流类型 I/O 应用 Java I/O 流的分类 O 按传输数据的“颗粒大小” 可分为字符流（Character Stream）和字节流（Byte Stream）。 ▶ 字节流以字节为单位传输数据，每次传送一个或多个字节。 ▶ 字符流以字符为单位传输数据，每次传送一个或多个字符。1  Java 命名惯例 凡是以 InputStream

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 358 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 358 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 358 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 355 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 354 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 356 10.2.3. Sending a Message To A Stream . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Sending a Message To A Stream To send a message to a particular stream, specify the name of the stream, as shown in the following example: Properties spring.rabbitmq.stream.name=my-stream Yaml spring: rabbitmq: stream: name: "my-stream" If a MessageConverter, StreamMessageConverter, or ProducerCustomizer bean is defined, it is associated automatically to the auto-configured RabbitStreamTemplate