Where is the source code for reactor-net

[张斌]

 I tried 2.5.0.BUILD-SNAPSHOT, and got error:

Exception in thread "main" java.lang.NoClassDefFoundError: reactor/core/util/Assert

at reactor.io.net.Spec$TcpServerSpec.<init>(Spec.java:306)

at reactor.io.net.ReactiveNet.tcpServer(ReactiveNet.java:221)

at reactor.io.net.ReactiveNet.tcpServer(ReactiveNet.java:197)

I cannot find the source code for reactor-net (2.5.0.BUILD-SNAPSHOT),  

but it's available in maven repo https://repo.spring.io/libs-snapshot/io/projectreactor/reactor-net/

[Stephane Maldini]

We don't call it reactor-net and separated out in reactor-netty (for netty binding and types directly like ByteBuf).

--
You received this message because you are subscribed to the Google Groups "reactor-framework" group.
To unsubscribe from this group and stop receiving emails from it, send an email to reactor-framew...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

--

Stephane Maldini | Reactor Project Lead, Spring Engineering | London | Pivotal

W: pivotal.io | T: @smaldini

[Stephane Maldini]

https://github.com/reactor/reactor-io and the tests have been ported so you can see how the API changed, obviously its not released yet as we polish core but we expect milestones before Spring 5 M1 this summer.

[张斌]

 

 Ah, ok, thanks,  so I can just use reactor-netty, and reactor-net is deprecated right?

[张斌]

 

 Just one quick question.

 Why NettyCodec.from(Codec<Buffer, IN, OUT> codec)  requires Buffer, but NOT ByteBuf directly ?

[张斌]

One more.

io.netty.handler.codec.ByteToMessageDecoder.java

protected void decode(final ChannelHandlerContext ctx, ByteBuf in, final List<Object> out) throws Exception

For netty, if the ByteBuf in doesn't have enough data to decode, it will expect more to come in. 

 So, how this method protected abstract IN decodeNext(SRC buffer, Object context) of Codec.java  should be implemented?

 does it work the same way?