He-Pin

Background

I'm a long time user of reactive streams in Scala. Originally with akka-streams, and then Monix Observable.

The transition from akka streams to Monix Observable I found pretty straight forward. I was motivated by wanting to use a lazy effect system, rather than working with scala.concurrent.Future.

More recently I've been considering fs2 and Zio Streams as an alternative to Monix Observable. This has largely been motivated by the fact that Monix doesn't have much ongoing development and is stuck on cats-effect 2.

I've not found the transition from Monix Observable to Zio Streams as easy as my earlier transition (from akka -> monix). While the ergonomics of the API are similar, performance characterics differ hugely.

Chunking

He-Pin

package com.alibaba.wireless.process.message.single.impl;

import com.alibaba.wireless.utils.NamedPoolThreadFactory;
import com.taobao.wireless.ripple2.core.util.SaneRejectedExecutionHandler;
import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;

import java.io.IOException;

He-Pin

package com.alibaba.wireless.process.message.single.impl;

import com.alibaba.wireless.utils.NamedPoolThreadFactory;
import com.taobao.wireless.ripple2.core.util.SaneRejectedExecutionHandler;
import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;

import java.io.IOException;

He-Pin

package fpmax

import scala.util.Try
import scala.io.StdIn.readLine

object App0 {
  def main: Unit = {
    println("What is your name?")

    val name = readLine()

He-Pin

Using:
* 8 threads
* 1024 concurrent connections
* run for 20 seconds
* 64 requests pipelined

## VERTX

norman@dev-linux:~/workspace/vertx-examples/src/main/java$ vertx run httpperf/PerfServer.java -instances 4

He-Pin

package com.pekall.cd.mdm.web.adminweb.rpc.builder;


import com.fasterxml.jackson.databind.JsonNode;
import com.ning.http.client.*;
import com.ning.http.multipart.FilePart;
import com.pekall.cd.mdm.web.adminweb.rpc.PageSplit;
import com.pekall.cd.mdm.web.adminweb.rpc.http.constant.MDMWebConstants;
import com.pekall.cd.mdm.web.adminweb.rpc.http.constant.MDMWebQueryKey;
import play.Logger;

He-Pin

    protected static class Pair<A, B> {
        public A a;
        public B b;

        public Pair() {
        }

        public Pair(A a, B b) {
            this.a = a;
            this.b = b;

He-Pin

{"result":"0","records":9,"devices":[{"language":null,"id":288,"type":50702,"policy":null,"password":null,"status":50001,"roles":1,"fullName":"admin","email":"pekall@pekall.com","firstName":"","lastName":null,"username":"admin","enterpriseId":1,"userId":1,"os":51201,"updateTime":1378709412000,"phoneNumber":null,"deviceUuid":"sdsdsdsdsddswdsdsdsss","iosUdid":"sdsdsdsdsddswdsdsdsss","lastCheckin":1378709412000,"deviceDetail":null,"createTime":null,"securityInfo":null,"labelNames":null,"appList":null,"connect":0,"policyName":"lccTestPolicy","settingName":"默认Android设置","deviceLabels":null,"policySpecial":0,"settingSpecial":0,"appSetting":null},{"language":null,"id":285,"type":50701,"policy":null,"password":null,"status":50001,"roles":1,"fullName":null,"email":null,"firstName":null,"lastName":null,"username":"huawei","enterpriseId":1,"userId":307,"os":51201,"updateTime":1378550603000,"phoneNumber":null,"deviceUuid":"000311e2a21b78c400000140f7fc70b6","iosUdid":"000311e2a21b78c400000140f7fc70b6","lastCheckin":137855

He-Pin

//for user service
    public static Result listUserDeviceWS(){
        return handleGET(new DefaultGETHandler("userName")
                .queryHandler(new DefaultGETHandler.QueryHandler() {
                    @Override
                    public Result handle(final String queryValue) {
                        final Promise<Result> resultPromise =
                                rpcUserDeviceList(queryValue)
                                .map(new F.Function<MDMDeviceListResponse, Result>() {
                                    @Override

He-Pin

package com.pekall.cd.mdm.web.admin.rpc.builder;

import com.ning.http.client.Request;
import com.ning.http.client.RequestBuilder;

/**
 * Author: kerr
 * Mail: pin.he@pekall.com
 */
public abstract class AbstractBuilder implements Builder {