rx

Documentation

Index

• func RunAsync(ctx context.Context, fun func(context.Context)) io.Closer
• func RunAsyncObserver(ctx context.Context, o Observer, fun func(context.Context) error) io.Closer
• type Observer

Functions

func RunAsync

func RunAsync(ctx context.Context, fun func(context.Context)) io.Closer

RunAsync runs `fun` asynchronously. The return value can be used to terminate the execution of the asynchronous method. The Close method of returned value ensures that the asynchronous function has finished its work.

func RunAsyncObserver

func RunAsyncObserver(ctx context.Context, o Observer, fun func(context.Context) error) io.Closer

RunAsyncObserver runs `fun` asynchronously and, when it’s finished, calls the appropriate observer method OnError/OnCompleted, depending on the result/error. The function `fun` should use only OnNext method of observer. The return value can be used to terminate the execution of the asynchronous method. The Close method of returned value ensures that the asynchronous function has finished its work.

Types

type Observer

type Observer interface {
	// OnError notifies the observer that the provider has experienced an error condition.
	OnError(err error)
	// OnCompleted notifies the observer that the provider has finished sending push-based notifications.
	OnCompleted()
}

Observer provides a mechanism for receiving push-based notifications.