< prev index next >
src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/MessageStreamConsumer.java
Print this page
*** 1,7 ****
/*
! * Copyright (c) 2015, 2016, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Oracle designates this
--- 1,7 ----
/*
! * Copyright (c) 2015, 2017, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Oracle designates this
*** 32,54 ****
/*
* A callback for consuming messages and related events on the stream.
*/
interface MessageStreamConsumer {
! void onText(MessagePart part, CharSequence data);
! void onBinary(MessagePart part, ByteBuffer data);
void onPing(ByteBuffer data);
void onPong(ByteBuffer data);
void onClose(int statusCode, CharSequence reason);
- void onError(Exception e);
-
/*
* Indicates the end of stream has been reached and there will be no further
* messages.
*/
void onComplete();
}
--- 32,54 ----
/*
* A callback for consuming messages and related events on the stream.
*/
interface MessageStreamConsumer {
! void onText(CharSequence data, MessagePart part);
! void onBinary(ByteBuffer data, MessagePart part);
void onPing(ByteBuffer data);
void onPong(ByteBuffer data);
void onClose(int statusCode, CharSequence reason);
/*
* Indicates the end of stream has been reached and there will be no further
* messages.
*/
void onComplete();
+
+ void onError(Throwable e);
}
< prev index next >