Class HoustonChannelUtils

java.lang.Object
boozilla.houston.gradle.HoustonChannelUtils
public class HoustonChannelUtils extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    HoustonChannelUtils()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> reactor.core.publisher.Flux<T>
    flux(HoustonEnvironment environment, Function<boozilla.houston.HoustonChannel, reactor.core.publisher.Flux<T>> channelFunction)
    Create a Flux using a HoustonEnvironment and a channel function.
    static <T> reactor.core.publisher.Mono<T>
    mono(HoustonEnvironment environment, Function<boozilla.houston.HoustonChannel, reactor.core.publisher.Mono<T>> channelFunction)
    Executes a given channel function on a Houston channel obtained from the provided environment.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • HoustonChannelUtils

      public HoustonChannelUtils()

  • Method Details

    • mono

      public static <T> reactor.core.publisher.Mono<T> mono(HoustonEnvironment environment, Function<boozilla.houston.HoustonChannel, reactor.core.publisher.Mono<T>> channelFunction)
      Executes a given channel function on a Houston channel obtained from the provided environment.
      Type Parameters:
      T - The type of the resulting Mono.
      Parameters:
      environment - The Houston environment.
      channelFunction - The channel function to execute on the Houston channel.
      Returns:
      A Mono representing the result of the channel function execution.

    • flux

      public static <T> reactor.core.publisher.Flux<T> flux(HoustonEnvironment environment, Function<boozilla.houston.HoustonChannel, reactor.core.publisher.Flux<T>> channelFunction)
      Create a Flux using a HoustonEnvironment and a channel function.
      Type Parameters:
      T - The type of elements in the Flux.
      Parameters:
      environment - The HoustonEnvironment object.
      channelFunction - A function that takes a HoustonChannel and returns a Flux of type T.
      Returns:
      The Flux object created using the HoustonEnvironment and channel function.