Package org.openqa.selenium.grid.router

Class ProxyWebsocketsIntoGrid

java.lang.Object

org.openqa.selenium.grid.router.ProxyWebsocketsIntoGrid

All Implemented Interfaces:

BiFunction<String,Consumer<org.openqa.selenium.remote.http.Message>,Optional<Consumer<org.openqa.selenium.remote.http.Message>>>

public class ProxyWebsocketsIntoGrid
extends Object
implements BiFunction<String,Consumer<org.openqa.selenium.remote.http.Message>,Optional<Consumer<org.openqa.selenium.remote.http.Message>>>

Proxies WebSocket connections from the Router to a Grid node.

After the Netty-side upgrade handshake completes (PostUpgradeHook), the pipeline is simplified: MessageInboundConverter, MessageOutboundConverter, and WebSocketMessageHandler are replaced by a WebSocketFrameProxy that forwards WebSocketFrame objects directly to the node-side WebSocket. This eliminates one intermediate object allocation and one executor-task submission per frame in each direction.

Constructor Summary

Constructors

Constructor	Description
ProxyWebsocketsIntoGrid(org.openqa.selenium.remote.http.HttpClient.Factory clientFactory, SessionMap sessions)

Method Summary

Modifier and Type	Method	Description
Optional<Consumer<org.openqa.selenium.remote.http.Message>>	apply(String uri, Consumer<org.openqa.selenium.remote.http.Message> downstream)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.BiFunction

andThen

Constructor Details

ProxyWebsocketsIntoGrid

public ProxyWebsocketsIntoGrid(org.openqa.selenium.remote.http.HttpClient.Factory clientFactory,
 SessionMap sessions)

Method Details

apply

public Optional<Consumer<org.openqa.selenium.remote.http.Message>> apply(String uri,
 Consumer<org.openqa.selenium.remote.http.Message> downstream)

Specified by:

apply in interface BiFunction<String,Consumer<org.openqa.selenium.remote.http.Message>,Optional<Consumer<org.openqa.selenium.remote.http.Message>>>