T
- type of the Publisher
s to be builtpublic static class HystrixCommands.PublisherBuilder<T> extends Object
Publisher
s.Constructor and Description |
---|
PublisherBuilder(org.reactivestreams.Publisher<T> publisher) |
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<T> |
build() |
HystrixCommands.PublisherBuilder<T> |
commandName(String commandName) |
HystrixCommands.PublisherBuilder<T> |
commandProperties(Function<com.netflix.hystrix.HystrixCommandProperties.Setter,com.netflix.hystrix.HystrixCommandProperties.Setter> commandProperties) |
HystrixCommands.PublisherBuilder<T> |
commandProperties(com.netflix.hystrix.HystrixCommandProperties.Setter commandProperties) |
HystrixCommands.PublisherBuilder<T> |
eager() |
HystrixCommands.PublisherBuilder<T> |
fallback(Function<Throwable,org.reactivestreams.Publisher<T>> fallback) |
HystrixCommands.PublisherBuilder<T> |
fallback(org.reactivestreams.Publisher<T> fallback) |
Function<com.netflix.hystrix.HystrixObservableCommand<T>,rx.Observable<T>> |
getObservableFunction() |
com.netflix.hystrix.HystrixObservableCommand.Setter |
getSetter() |
HystrixCommands.PublisherBuilder<T> |
groupName(String groupName) |
HystrixCommands.PublisherBuilder<T> |
setter(com.netflix.hystrix.HystrixObservableCommand.Setter setter) |
reactor.core.publisher.Flux<T> |
toFlux() |
reactor.core.publisher.Mono<T> |
toMono() |
HystrixCommands.PublisherBuilder<T> |
toObservable(Function<com.netflix.hystrix.HystrixObservableCommand<T>,rx.Observable<T>> toObservable) |
public PublisherBuilder(org.reactivestreams.Publisher<T> publisher)
public HystrixCommands.PublisherBuilder<T> commandName(String commandName)
public HystrixCommands.PublisherBuilder<T> groupName(String groupName)
public HystrixCommands.PublisherBuilder<T> fallback(org.reactivestreams.Publisher<T> fallback)
public HystrixCommands.PublisherBuilder<T> fallback(Function<Throwable,org.reactivestreams.Publisher<T>> fallback)
public HystrixCommands.PublisherBuilder<T> setter(com.netflix.hystrix.HystrixObservableCommand.Setter setter)
public HystrixCommands.PublisherBuilder<T> commandProperties(com.netflix.hystrix.HystrixCommandProperties.Setter commandProperties)
public HystrixCommands.PublisherBuilder<T> commandProperties(Function<com.netflix.hystrix.HystrixCommandProperties.Setter,com.netflix.hystrix.HystrixCommandProperties.Setter> commandProperties)
public HystrixCommands.PublisherBuilder<T> eager()
public HystrixCommands.PublisherBuilder<T> toObservable(Function<com.netflix.hystrix.HystrixObservableCommand<T>,rx.Observable<T>> toObservable)
public org.reactivestreams.Publisher<T> build()
public Function<com.netflix.hystrix.HystrixObservableCommand<T>,rx.Observable<T>> getObservableFunction()
public com.netflix.hystrix.HystrixObservableCommand.Setter getSetter()
public reactor.core.publisher.Flux<T> toFlux()
public reactor.core.publisher.Mono<T> toMono()
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.