Pinned Loading

1. atleon/atleon atleon/atleon Public

   Embeddable reactive stream processing library

   Java 48 7

2. reactor/reactor-core reactor/reactor-core Public

   Non-Blocking Reactive Foundation for the JVM

   Java 5.2k 1.3k

3. Delayed Kafka Processing Delayed Kafka Processing

   1

   class DelayedProcessingStream : AloStream<DelayedProcessingConfig>() {

   2

   3

     override fun start(config: DelayedProcessingConfig): Disposable {

   4

       val receiver = config.buildKafkaReceiver()

   5

4. Reactive OkHttp Client Reactive OkHttp Client

   1

   import okhttp3.Call;

   2

   import okhttp3.Callback;

   3

   import okhttp3.HttpUrl;

   4

   import okhttp3.Request;

   5

   import okhttp3.Response;

5. Reactor gRPC with Mongo Reactor gRPC with Mongo

   1

   import javax.inject.Inject;

   2

   3

   import org.bson.Document;

   4

   5

   import com.expediagroup.hello.api.proto.HelloRequestDto;

6. AWS S3: High Speed Bucket Killer AWS S3: High Speed Bucket Killer

   1

   package org.codegas.amazon.s3

   2

   3

   import reactor.core.publisher.Flux

   4

   import reactor.core.publisher.Mono

   5

   import reactor.core.scheduler.Schedulers