Fixed CI
This commit is contained in:
parent
b7f870efb7
commit
b99a2e517a
|
@ -27,14 +27,16 @@ public class TWebsocket extends Resource<TWebsocket> implements WebsocketClient
|
|||
private final IAPIEnvironment environment;
|
||||
private final URI uri;
|
||||
private final String address;
|
||||
private final boolean binary;
|
||||
|
||||
private @Nullable WebSocket websocket;
|
||||
|
||||
public TWebsocket(ResourceGroup<TWebsocket> limiter, IAPIEnvironment environment, URI uri, String address, HttpHeaders headers, int timeout) {
|
||||
public TWebsocket(ResourceGroup<TWebsocket> limiter, IAPIEnvironment environment, URI uri, String address, HttpHeaders headers, int timeout, boolean binary) {
|
||||
super(limiter);
|
||||
this.environment = environment;
|
||||
this.uri = uri;
|
||||
this.address = address;
|
||||
this.binary = binary;
|
||||
}
|
||||
|
||||
public void connect() {
|
||||
|
@ -76,6 +78,11 @@ public void sendBinary(ByteBuffer message) {
|
|||
websocket.send(array);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean isBinary() {
|
||||
return binary;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void dispose() {
|
||||
super.dispose();
|
||||
|
|
Loading…
Reference in New Issue