Instantly share code, notes, and snippets.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters package lithium; import org.reactivestreams.Publisher; //import com.fasterxml.jackson.dataformat.cbor.CBORFactory; import io.reactivesocket.AbstractReactiveSocket; import io.reactivesocket.ConnectionSetupPayload; import io.reactivesocket.Payload; import io.reactivesocket.ReactiveSocket;Response to https://twitter.com/jeffreymaxwell/status/705760483391963136 requiring more than the 77 characters left on Twitter.
DISCLAIMER: The quality of writing and thinking here is aligned with a Twitter conversation, not a blog post, presentation, or book ;-)
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters package pubsub; import java.nio.ByteBuffer; import java.util.concurrent.TimeUnit; import rx.Observable; import rx.Observable.Operator; import rx.Scheduler.Worker; import rx.Subscriber; import rx.functions.Func1; This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters import java.util.concurrent.atomic.AtomicInteger; import rx.Observable; import rx.Subscriber; import rx.schedulers.Schedulers; public class ParallelExecution { public static void main(String[] args) { // System.out.println("------------ mergingAsync"); This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters package reactive_streams_interop; import java.util.concurrent.atomic.AtomicInteger; import rx.Observable; import rx.schedulers.Schedulers; public class RxJavaPublishZip { public static void main(String... args) { This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import rx.Observable; import rx.Subscriber; public class RetryWhenTestsConditional { public static void main(String[] args) { This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters import java.util.concurrent.TimeUnit; import rx.Observable; import rx.Subscriber; public class RetryWhenTests { public static void main(String[] args) { Observable.create((Subscriber<? super String> s) -> { This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters import java.util.concurrent.CountDownLatch; import rx.Observable; import rx.observables.ConnectableObservable; import rx.schedulers.Schedulers; /** * This shows how a "reactive pull" compliant "cold" Observable, when multicasted, becomes "hot" and each Subscriber * must then choose its strategy for overflow. */Synchronous RESTful communication between Microservices is an anti-pattern ... you seem to being saying that the Netflix architecture (hystrix, eureka, ribbon, ..) is broken ... hmm what would @benjchristensen say?
You can’t perform that action at this time.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4