Package com.microsoft.playwright.impl

Class JsonPipe

java.lang.Object

com.microsoft.playwright.impl.LoggingSupport

com.microsoft.playwright.impl.ChannelOwner

com.microsoft.playwright.impl.JsonPipe

All Implemented Interfaces:

Transport

class JsonPipe
extends ChannelOwner
implements Transport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	JsonPipe.EventType

Field Summary

Fields

Modifier and Type	Field	Description
private final Queue<com.google.gson.JsonObject>	incoming
private boolean	isClosed
private ListenerCollection<JsonPipe.EventType>	listeners

Fields inherited from class com.microsoft.playwright.impl.ChannelOwner

connection, guid, initializer, type

Constructor Summary

Constructors

Constructor	Description
JsonPipe(ChannelOwner parent, String type, String guid, com.google.gson.JsonObject initializer)

Method Summary

Modifier and Type	Method	Description
private void	checkIfClosed()
void	close()
protected void	handleEvent(String event, com.google.gson.JsonObject params)
(package private) void	offClose(Consumer<JsonPipe> handler)
(package private) void	onClose(Consumer<JsonPipe> handler)
com.google.gson.JsonObject	poll(Duration timeout)
void	send(com.google.gson.JsonObject message)

Methods inherited from class com.microsoft.playwright.impl.ChannelOwner

adopt, disposeChannelOwner, runUntil, sendMessage, sendMessage, sendMessageAsync, toProtocolRef, withLogging, withWaitLogging

Methods inherited from class com.microsoft.playwright.impl.LoggingSupport

logApi, logApiIfEnabled, logWithTimestamp, withLogging

Methods inherited from class java.lang.Object

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

Field Details

incoming

private final Queue<com.google.gson.JsonObject> incoming

listeners

private ListenerCollection<JsonPipe.EventType> listeners

isClosed

private boolean isClosed

Constructor Details

JsonPipe

JsonPipe(ChannelOwner parent,
 String type,
 String guid,
 com.google.gson.JsonObject initializer)

Method Details

send

public void send(com.google.gson.JsonObject message)

Specified by:

send in interface Transport

poll

public com.google.gson.JsonObject poll(Duration timeout)

Specified by:

poll in interface Transport

close

public void close()
           throws IOException

Specified by:

close in interface Transport

Throws:

IOException

onClose

void onClose(Consumer<JsonPipe> handler)

offClose

void offClose(Consumer<JsonPipe> handler)

handleEvent

protected void handleEvent(String event,
 com.google.gson.JsonObject params)

Overrides:

handleEvent in class ChannelOwner

checkIfClosed

private void checkIfClosed()