File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
rsocket-core/src/main/java/io/rsocket/core Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change 27
27
import io .rsocket .DuplexConnection ;
28
28
import io .rsocket .Payload ;
29
29
import io .rsocket .RSocket ;
30
- import io .rsocket .exceptions .ApplicationErrorException ;
31
30
import io .rsocket .frame .*;
32
31
import io .rsocket .frame .decoder .PayloadDecoder ;
33
32
import io .rsocket .internal .SynchronizedIntObjectHashMap ;
@@ -339,7 +338,7 @@ private void handleFrame(ByteBuf frame) {
339
338
case ERROR :
340
339
receiver = channelProcessors .get (streamId );
341
340
if (receiver != null ) {
342
- receiver .onError (new ApplicationErrorException ( ErrorFrameCodec . dataUtf8 ( frame ) ));
341
+ receiver .onError (io . rsocket . exceptions . Exceptions . from ( streamId , frame ));
343
342
}
344
343
break ;
345
344
case NEXT_COMPLETE :
You can’t perform that action at this time.
0 commit comments