APIdia Launch Partner

Top Inners Fields Constructors Methods

jdk.internal.net.http.websocket

public Class MessageQueue

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.websocket.MessageQueue

Imports

java.io.IOException, java.nio.ByteBuffer, .CharBuffer, java.util.concurrent.CompletableFuture, java.util.concurrent.atomic.AtomicInteger, java.util.function.BiConsumer, .Supplier

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	MessageQueue.Message
public static interface	MessageQueue.QueueCallback<R, E extends Throwable>
private static enum	MessageQueue.Type

Field Summary

Modifier and Type	Field and Description
private final MessageQueue.Message[]	elements
private volatile int	head
private final AtomicInteger	tail

Constructor Summary

Access	Constructor and Description
public	MessageQueue(int capacity)

Method Summary

Modifier and Type	Method and Description
private <T> void	add(MessageQueue.Type type, Supplier<? extends ByteBuffer> binarySupplier, ByteBuffer binary, CharBuffer text, boolean isLast, int statusCode, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> void	addBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> void	addClose(int statusCode, CharBuffer reason, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> void	addPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> void	addPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> void	addPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> void	addText(CharBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<T> future)
protected static int	effectiveCapacityOf(int n)
public boolean	isEmpty()
public <R, E extends Throwable> R	peek(MessageQueue.QueueCallback<R, E> callback)
public void	remove()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

elements	back to summary
private final MessageQueue.Message[] elements

head	back to summary
private volatile int head

tail	back to summary
private final AtomicInteger tail

Constructor Detail

MessageQueue	back to summary
public MessageQueue(int capacity)

Method Detail

add	back to summary
private <T> void add(MessageQueue.Type type, Supplier<? extends ByteBuffer> binarySupplier, ByteBuffer binary, CharBuffer text, boolean isLast, int statusCode, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws IOException

addBinary	back to summary
public <T> void addBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws IOException

addClose	back to summary
public <T> void addClose(int statusCode, CharBuffer reason, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws IOException

addPing	back to summary
public <T> void addPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws IOException

addPong	back to summary
public <T> void addPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws IOException

addPong	back to summary
public <T> void addPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws IOException

addText	back to summary
public <T> void addText(CharBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<T> future) throws IOException

effectiveCapacityOf	back to summary
protected static int effectiveCapacityOf(int n)

isEmpty	back to summary
public boolean isEmpty()

peek	back to summary
public <R, E extends Throwable> R peek(MessageQueue.QueueCallback<R, E> callback) throws QueueCallback-:E Annotations @SuppressWarnings:unchecked

remove	back to summary
public void remove()

jdk.internal.net.http.websocket back to summary

private Class MessageQueue.Message

Class Inheritance

extends Object

java.lang.Object
jdk.internal.net.http.websocket.MessageQueue.Message

Field Summary

Modifier and Type	Field and Description
private BiConsumer<T, U>	action
private Object	attachment
private ByteBuffer	binary
private Supplier<? extends ByteBuffer>	binarySupplier
private CompletableFuture<T>	future
private boolean	isLast
private volatile boolean	ready
private int	statusCode
private CharBuffer	text
private MessageQueue.Type	type

Constructor Summary

Access	Constructor and Description
private	Message()

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

action	back to summary
private BiConsumer<T, U> action Annotations @SuppressWarnings:rawtypes

attachment	back to summary
private Object attachment

binary	back to summary
private ByteBuffer binary

binarySupplier	back to summary
private Supplier<? extends ByteBuffer> binarySupplier

future	back to summary
private CompletableFuture<T> future Annotations @SuppressWarnings:rawtypes

isLast	back to summary
private boolean isLast

ready	back to summary
private volatile boolean ready

statusCode	back to summary
private int statusCode

text	back to summary
private CharBuffer text

type	back to summary
private MessageQueue.Type type

Constructor Detail

Message	back to summary
private Message()

jdk.internal.net.http.websocket back to summary

public Interface MessageQueue.QueueCallback<R, E extends Throwable>

Method Summary

Modifier and Type	Method and Description
public <T> R	onBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> R	onClose(int statusCode, CharBuffer reason, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public R	onEmpty()
public <T> R	onPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> R	onPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> R	onPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)
public <T> R	onText(CharBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future)

Method Detail

onBinary	back to summary
public <T> R onBinary(ByteBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws QueueCallback:E

onClose	back to summary
public <T> R onClose(int statusCode, CharBuffer reason, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws QueueCallback:E

onEmpty	back to summary
public R onEmpty() throws QueueCallback:E

onPing	back to summary
public <T> R onPing(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws QueueCallback:E

onPong	back to summary
public <T> R onPong(ByteBuffer message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws QueueCallback:E

onPong	back to summary
public <T> R onPong(Supplier<? extends ByteBuffer> message, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws QueueCallback:E

onText	back to summary
public <T> R onText(CharBuffer message, boolean isLast, T attachment, BiConsumer<? super T, ? super Throwable> action, CompletableFuture<? super T> future) throws QueueCallback:E

jdk.internal.net.http.websocket back to summary

private final Enum MessageQueue.Type

Class Inheritance

extends Enum<MessageQueue.Type>

java.lang.Object
java.lang.Enum
jdk.internal.net.http.websocket.MessageQueue.Type

Field Summary

Modifier and Type	Field and Description
public static final MessageQueue.Type	BINARY
public static final MessageQueue.Type	CLOSE
public static final MessageQueue.Type	PING
public static final MessageQueue.Type	PONG
public static final MessageQueue.Type	TEXT

Constructor Summary

Access	Constructor and Description
private	Type()

Method Summary

Modifier and Type	Method and Description
public static MessageQueue.Type	valueOf(String name)
public static MessageQueue.Type[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

BINARY	back to summary
public static final MessageQueue.Type BINARY

CLOSE	back to summary
public static final MessageQueue.Type CLOSE

PING	back to summary
public static final MessageQueue.Type PING

PONG	back to summary
public static final MessageQueue.Type PONG

TEXT	back to summary
public static final MessageQueue.Type TEXT

Constructor Detail

Type	back to summary
private Type()

Method Detail

valueOf	back to summary
public static MessageQueue.Type valueOf(String name)

values	back to summary
public static MessageQueue.Type[] values()