@RestController public class TurbineController extends Object
TurbineController(rx.subjects.PublishSubject<Map<String,Object>> hystrixSubject)
reactor.core.publisher.Flux<String>
stream()
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public TurbineController(rx.subjects.PublishSubject<Map<String,Object>> hystrixSubject)
@GetMapping(produces="text/event-stream") public reactor.core.publisher.Flux<String> stream()
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.