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 class	JsonPipe.EventType

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.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, java.lang.String type, java.lang.String guid, com.google.gson.JsonObject initializer)

Method Summary

Modifier and Type	Method	Description
private void	checkIfClosed()
void	close()
protected void	handleEvent(java.lang.String event, com.google.gson.JsonObject params)
(package private) void	offClose(java.util.function.Consumer<JsonPipe> handler)
(package private) void	onClose(java.util.function.Consumer<JsonPipe> handler)
com.google.gson.JsonObject	poll(java.time.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 Detail

incoming

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

listeners

private ListenerCollection<JsonPipe.EventType> listeners

isClosed

private boolean isClosed

Constructor Detail

JsonPipe

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

Method Detail

send

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

Specified by:

send in interface Transport

poll

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

Specified by:

poll in interface Transport

close

public void close()
           throws java.io.IOException

Specified by:

close in interface Transport

Throws:

java.io.IOException

onClose

void onClose(java.util.function.Consumer<JsonPipe> handler)

offClose

void offClose(java.util.function.Consumer<JsonPipe> handler)

handleEvent

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

Overrides:

handleEvent in class ChannelOwner

checkIfClosed

private void checkIfClosed()