Package com.microsoft.playwright.impl

Class ReaderThread

java.lang.Object

java.lang.Thread

com.microsoft.playwright.impl.ReaderThread

All Implemented Interfaces:

Runnable

class ReaderThread
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Exception	exception
private final DataInputStream	in
(package private) boolean	isClosing
private final BlockingQueue<com.google.gson.JsonObject>	queue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ReaderThread(DataInputStream in, BlockingQueue<com.google.gson.JsonObject> queue)

Method Summary

Modifier and Type	Method	Description
private static int	readIntLE(DataInputStream in)
private String	readMessage()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

in

private final DataInputStream in

queue

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

isClosing

volatile boolean isClosing

exception

volatile Exception exception

Constructor Details

ReaderThread

ReaderThread(DataInputStream in,
 BlockingQueue<com.google.gson.JsonObject> queue)

Method Details

readIntLE

private static int readIntLE(DataInputStream in)
                      throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

readMessage

private String readMessage()
                    throws IOException

Throws:

IOException