Search Results for "observer"

...It helps you write cleaner and simpler code by providing methods for solving problems quickly, and is easy to maintain and understand. RxJava works by extending the observer pattern in order to support sequences of data/events. It also allows you to compose sequences together declaratively through added operators, all while abstracting away concerns like low-level threading, thread-safety, concurrent data structures and synchronization. RxJava is commonly used for running simple background computations. ...

...Eg it does not run any network stuff on the main (UI) thread. The WAMP layer is using Java 8 CompletableFuture for WAMP actions (call, register, publish, and subscribe) and the Observer pattern for WAMP session, subscription and registration lifecycle events. The library is MIT licensed, maintained by the Crossbar.io Project, tested using the AutobahnTestsuite and published as a JAR to Maven and as a Docker toolchain image to Dockerhub.

This library allows the usage of RxJava with the new Android M permission model. If you need to trigger the permission request from a specific event, you need to setup your event as an observable inside an initialization phase. You can use JakeWharton/RxBinding to turn your view to an observable (not included in the library). Because your app may be restarted during the permission request, the request must be done during an initialization phase. This may be Activity.onCreate, or...

Helps to develop and test event-based multi-threaded Java application. Because of method called as API-Evolution the Happy Java Library is fully downward compatible. The library contains following functionality: MultiLock, Parallel loops, Collections, Controllers, Generators, Delegates, Streams.

...For non-disposable tokens (tokens that can be reused), after obtaining the token, save it for repeated use, and use retryWhen() to automatically re-acquire the token when it expires, making the process of token acquisition completely transparent and simplified. Convert the returned data into a more convenient format and give it to the Observer.

...It allows developers to define and post custom events that can be observed by multiple parts of an app, such as UI controllers, services, or background workers, without requiring direct references between senders and receivers. Unlike simple observer patterns, AndroidEventBus typically integrates with Android lifecycles so that subscribers are automatically registered, paused, or cleaned up based on activity/fragment state — reducing memory leaks and errant behavior during configuration changes. The library aims to simplify common inter-component messaging tasks (like posting a login success event or notifying multiple listeners of state changes) while preserving type safety and performance.

Small general-purpose Java library. Examples are provided in JUnit tests and demo projects. Compatible with NetBeans and Eclipse.

TcpChannel is a simple, small API to allow processes to communicate using TCP sockets based on NIO implementations. The API presents the communication between processes using an observer pattern for handling received messages and an asynchronous send method for sending. Generally, writing NIO socket handling is non-trivial. TcpChannel exists to let Java developers write processes that communicate with each other using a simple send and receive pattern.