Top Description Fields Constructors Methods
org.eclipse.jetty.server.internal

public Class CompletionStreamWrapper

extends Wrapper
Class Inheritance
Imports
java.util.ArrayList, .List, java.util.function.Consumer, org.eclipse.jetty.server.HttpStream, .Request, org.eclipse.jetty.util.ExceptionUtil
A HttpStream wrapper that keeps a list of listeners. This is optimized for multiple completion event listeners being added, without other stream wrappers interleaved.

Field Summary

Modifier and TypeField and Description
private final List<Consumer<Throwable>>
_listeners

Constructor Summary

AccessConstructor and Description
public
CompletionStreamWrapper(HttpStream stream, Consumer<Throwable> listener)

Method Summary

Modifier and TypeMethod and Description
public HttpStream
addListener(Consumer<Throwable> listener)

public void
failed(Throwable
the reason for the operation failure
x)

Overrides org.eclipse.jetty.server.HttpStream.Wrapper.failed.

Overrides default org.eclipse.jetty.util.Callback.failed.

Callback invoked when the operation fails.

private void
onCompletion(Throwable x)

public void
succeeded()

Overrides org.eclipse.jetty.server.HttpStream.Wrapper.succeeded.

Overrides default org.eclipse.jetty.util.Callback.succeeded.

Callback invoked when the operation completes.

Inherited from org.eclipse.jetty.server.HttpStream.Wrapper:
consumeAvailabledemandgetIdgetIdleTimeoutgetInvocationTypegetTunnelSupportgetWrappedisCommittedprepareResponsepushreadsendsetIdleTimeout

Field Detail

_listenersback to summary
private final List<Consumer<Throwable>> _listeners

Constructor Detail

CompletionStreamWrapperback to summary
public CompletionStreamWrapper(HttpStream stream, Consumer<Throwable> listener)

Method Detail

addListenerback to summary
public HttpStream addListener(Consumer<Throwable> listener)
failedback to summary
public void failed(Throwable x)

Overrides org.eclipse.jetty.server.HttpStream.Wrapper.failed.

Overrides default org.eclipse.jetty.util.Callback.failed.

Doc from org.eclipse.jetty.util.Callback.failed.

Callback invoked when the operation fails.

Parameters
x:Throwable

the reason for the operation failure

Annotations
@Override
onCompletionback to summary
private void onCompletion(Throwable x)
succeededback to summary
public void succeeded()

Overrides org.eclipse.jetty.server.HttpStream.Wrapper.succeeded.

Overrides default org.eclipse.jetty.util.Callback.succeeded.

Doc from org.eclipse.jetty.util.Callback.succeeded.

Callback invoked when the operation completes.

Annotations
@Override