Package com.microsoft.playwright.impl

Class PipeTransport

java.lang.Object

com.microsoft.playwright.impl.PipeTransport

All Implemented Interfaces:

Transport

public class PipeTransport
extends Object
implements Transport

Field Summary

Fields

Modifier and Type	Field	Description
private final BlockingQueue<com.google.gson.JsonObject>	incoming
private boolean	isClosed
private final BlockingQueue<String>	outgoing
private final ReaderThread	readerThread
private final WriterThread	writerThread

Constructor Summary

Constructors

Constructor	Description
PipeTransport(InputStream input, OutputStream output)

Method Summary

Modifier and Type	Method	Description
void	close()
com.google.gson.JsonObject	poll(Duration timeout)
void	send(com.google.gson.JsonObject message)

Methods inherited from class java.lang.Object

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

Field Details

incoming

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

outgoing

private final BlockingQueue<String> outgoing

readerThread

private final ReaderThread readerThread

writerThread

private final WriterThread writerThread

isClosed

private boolean isClosed

Constructor Details

PipeTransport

PipeTransport(InputStream input,
 OutputStream output)

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