< 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 >