BodyValueFlowProcessor

Warning:
Fauna is decommissioning FQL v4 on June 30, 2025.

This driver is not compatible with FQL v10, the latest version. Fauna accounts created after August 21, 2024 must use FQL v10.
Ensure you migrate existing projects to the official v10 driver by the v4 EOL date: https://github.com/fauna/fauna-jvm.

For more information, see the v4 end of life (EOL) announcement and related FAQ.

java.lang.Object
- java.util.concurrent.SubmissionPublisher<Value>
- - com.faunadb.client.streaming.BodyValueFlowProcessor

All Implemented Interfaces:

AutoCloseable, Flow.Processor<List<ByteBuffer>,Value>, Flow.Publisher<Value>, Flow.Subscriber<List<ByteBuffer>>
```
public class BodyValueFlowProcessor
extends SubmissionPublisher<Value>
implements Flow.Processor<List<ByteBuffer>,Value>
```

Constructor Summary

Constructors
Constructor Description

BodyValueFlowProcessor(com.fasterxml.jackson.databind.ObjectMapper json, Connection connection)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`
`void`	`onError(Throwable throwable)`
`void`	`onNext(List<ByteBuffer> items)`
`void`	`onSubscribe(Flow.Subscription subscription)`
`void`	`subscribe(Flow.Subscriber<? super Value> subscriber)`

Methods inherited from class java.util.concurrent.SubmissionPublisher
close, closeExceptionally, consume, estimateMaximumLag, estimateMinimumDemand, getClosedException, getExecutor, getMaxBufferCapacity, getNumberOfSubscribers, getSubscribers, hasSubscribers, isClosed, isSubscribed, offer, offer, submit

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - BodyValueFlowProcessor
```
public BodyValueFlowProcessor(com.fasterxml.jackson.databind.ObjectMapper json,
                              Connection connection)
```
- Method Detail
  - subscribe
```
public void subscribe(Flow.Subscriber<? super Value> subscriber)
```
    Specified by:
    
    subscribe in interface Flow.Publisher<Value>
    
    Overrides:
    
    subscribe in class SubmissionPublisher<Value>
  - onSubscribe
```
public void onSubscribe(Flow.Subscription subscription)
```
    Specified by:
    
    onSubscribe in interface Flow.Subscriber<List<ByteBuffer>>
  - onNext
```
public void onNext(List<ByteBuffer> items)
```
    Specified by:
    
    onNext in interface Flow.Subscriber<List<ByteBuffer>>
  - onError
```
public void onError(Throwable throwable)
```
    Specified by:
    
    onError in interface Flow.Subscriber<List<ByteBuffer>>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface Flow.Subscriber<List<ByteBuffer>>