Package io.netty.handler.codec.string

Examples of io.netty.handler.codec.string.StringDecoder

44
45
46
47
48
49
50
51
52
53
54
    public int collectMessages() {
        Observable<ObservableConnection<String, ByteBuf>> connectionObservable =
                RxNetty.createTcpClient("localhost", port, new PipelineConfigurator<String, ByteBuf>() {
                    @Override
                    public void configureNewPipeline(ChannelPipeline pipeline) {
                        pipeline.addLast(new StringDecoder());
                    }
                }).connect();
        Iterable<String> msgIterable = connectionObservable.flatMap(new Func1<ObservableConnection<String, ByteBuf>, Observable<String>>() {
            @Override
            public Observable<String> call(ObservableConnection<String, ByteBuf> connection) {
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
        // Configure the pipeline factory.
        b.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new StringEncoder(CharsetUtil.ISO_8859_1),
                        new StringDecoder(CharsetUtil.ISO_8859_1),
                        new QuoteOfTheMomentClientHandler());
            }
        });

        // Enable broadcast
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
        // Configure the pipeline factory.
        b.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new StringEncoder(CharsetUtil.ISO_8859_1),
                        new StringDecoder(CharsetUtil.ISO_8859_1),
                        new QuoteOfTheMomentServerHandler());
            }
        });

        // Enable broadcast
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
        // Set up the client-side pipeline factory.
        cb.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new StringDecoder(),
                        new StringEncoder(),
                        new LoggingHandler(InternalLogLevel.INFO));
            }
        });
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
    }

    @Override
    public ChannelPipeline getPipeline() throws Exception {
        final ChannelPipeline pipeline = Channels.pipeline();
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());
        pipeline.addLast("executor", executionHandler);
        pipeline.addLast("handler", new EchoCloseServerHandler());
        return pipeline;
    }
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
        ChannelPipeline pipeline = pipeline();

        // Add the text line codec combination first,
        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
                8192, Delimiters.lineDelimiter()));
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());

        // and then business logic.
        pipeline.addLast("handler", new TelnetServerHandler());
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
                new DefaultLocalClientChannelFactory());

        cb.setPipelineFactory(new ChannelPipelineFactory() {
            public ChannelPipeline getPipeline() throws Exception {
                return Channels.pipeline(
                        new StringDecoder(),
                        new StringEncoder(),
                        new LoggingHandler(InternalLogLevel.INFO));
            }
        });
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
        pipeline.addLast("ssl", new SslHandler(engine));

        // On top of the SSL handler, add the text line codec.
        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
                8192, Delimiters.lineDelimiter()));
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());

        // and then business logic.
        pipeline.addLast("handler", new SecureChatClientHandler());
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
        ChannelPipeline pipeline = pipeline();

        // Add the text line codec combination first,
        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
                8192, Delimiters.lineDelimiter()));
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());

        // and then business logic.
        pipeline.addLast("handler", new TelnetClientHandler());
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
        pipeline.addLast("ssl", new SslHandler(engine));

        // On top of the SSL handler, add the text line codec.
        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
                8192, Delimiters.lineDelimiter()));
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());

        // and then business logic.
        pipeline.addLast("handler", new SecureChatServerHandler());
View Full Code Here
TOP

Related Classes of io.netty.handler.codec.string.StringDecoder

  • com.github.dreamhead.moco.internal.MocoSocketServer
  • com.github.dreamhead.moco.runner.watcher.ShutdownMocoRunnerWatcher
  • io.netty.example.filetransfer.FileServer
  • io.netty.example.local.LocalExample
  • io.netty.example.local.LocalExampleMultithreaded
  • io.netty.example.local.LocalServerPipelineFactory
  • io.netty.example.qotm.QuoteOfTheMomentClient
  • io.netty.example.qotm.QuoteOfTheMomentServer
  • io.netty.example.rxtx.RxtxClient
  • io.netty.example.securechat.SecureChatClientInitializer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.