src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/WebSocketImpl.java
equal
deleted
inserted
replaced
453 // ordered in the channel. The reason is to avoid an interference with |
453 // ordered in the channel. The reason is to avoid an interference with |
454 // any unrelated to the channel calls to onOpen, onClose and onError. |
454 // any unrelated to the channel calls to onOpen, onClose and onError. |
455 return new MessageStreamConsumer() { |
455 return new MessageStreamConsumer() { |
456 |
456 |
457 @Override |
457 @Override |
458 public void onText(MessagePart part, CharSequence data) { |
458 public void onText(CharSequence data, MessagePart part) { |
459 receiver.acknowledge(); |
459 receiver.acknowledge(); |
460 synchronized (WebSocketImpl.this.lock) { |
460 synchronized (WebSocketImpl.this.lock) { |
461 try { |
461 try { |
462 listener.onText(WebSocketImpl.this, data, part); |
462 listener.onText(WebSocketImpl.this, data, part); |
463 } catch (Exception e) { |
463 } catch (Exception e) { |
465 } |
465 } |
466 } |
466 } |
467 } |
467 } |
468 |
468 |
469 @Override |
469 @Override |
470 public void onBinary(MessagePart part, ByteBuffer data) { |
470 public void onBinary(ByteBuffer data, MessagePart part) { |
471 receiver.acknowledge(); |
471 receiver.acknowledge(); |
472 synchronized (WebSocketImpl.this.lock) { |
472 synchronized (WebSocketImpl.this.lock) { |
473 try { |
473 try { |
474 listener.onBinary(WebSocketImpl.this, data.slice(), part); |
474 listener.onBinary(WebSocketImpl.this, data.slice(), part); |
475 } catch (Exception e) { |
475 } catch (Exception e) { |