java.lang.Object

org.elasticsearch.transport.InboundAggregator

All Implemented Interfaces:: java.io.Closeable, java.lang.AutoCloseable, Releasable

public class InboundAggregator
extends java.lang.Object
implements Releasable

Constructor Summary

Constructors
Constructor	Description
`InboundAggregator(java.util.function.Supplier<CircuitBreaker> circuitBreaker, java.util.function.Function<java.lang.String,RequestHandlerRegistry<TransportRequest>> registryFunction)`

Method Summary

Modifier and Type	Method	Description
`void`	`aggregate(ReleasableBytesReference content)`
`void`	`close()`
`InboundMessage`	`finishAggregation()`
`void`	`headerReceived(Header header)`
`boolean`	`isAggregating()`

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- InboundAggregator
  
  public InboundAggregator(java.util.function.Supplier<CircuitBreaker> circuitBreaker, java.util.function.Function<java.lang.String,RequestHandlerRegistry<TransportRequest>> registryFunction)
Method Details
- headerReceived
  
  public void headerReceived(Header header)
- aggregate
  
  public void aggregate(ReleasableBytesReference content)
- finishAggregation
  
  public InboundMessage finishAggregation() throws java.io.IOException
  
  Throws:
  
  java.io.IOException
- isAggregating
  
  public boolean isAggregating()
- close
  
  public void close()
  
  Specified by:
  
  close in interface java.lang.AutoCloseable
  
  Specified by:
  
  close in interface java.io.Closeable
  
  Specified by:
  
  close in interface Releasable