public class io.smallrye.mutiny.vertx.MultiHelper extends java.lang.Object
{
public void <init>()
{
io.smallrye.mutiny.vertx.MultiHelper v;
v := @this: io.smallrye.mutiny.vertx.MultiHelper;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static io.vertx.core.streams.ReadStream toReadStream(io.smallrye.mutiny.Multi)
{
io.vertx.core.streams.ReadStream v;
java.util.function.Function v;
io.smallrye.mutiny.Multi v;
v := @parameter: io.smallrye.mutiny.Multi;
v = staticinvoke <java.util.function.Function: java.util.function.Function identity()>();
v = staticinvoke <io.smallrye.mutiny.vertx.ReadStreamSubscriber: io.vertx.core.streams.ReadStream asReadStream(java.util.concurrent.Flow$Publisher,java.util.function.Function)>(v, v);
return v;
}
public static io.smallrye.mutiny.Multi toMulti(io.vertx.core.streams.ReadStream, java.util.function.Function)
{
io.vertx.core.streams.ReadStream v;
io.smallrye.mutiny.vertx.MultiReadStream v;
java.util.function.Function v;
v := @parameter: io.vertx.core.streams.ReadStream;
v := @parameter: java.util.function.Function;
v = new io.smallrye.mutiny.vertx.MultiReadStream;
specialinvoke v.<io.smallrye.mutiny.vertx.MultiReadStream: void <init>(io.vertx.core.streams.ReadStream,java.util.function.Function)>(v, v);
return v;
}
public static io.smallrye.mutiny.Multi toMulti(io.vertx.core.streams.ReadStream)
{
io.vertx.core.streams.ReadStream v;
io.smallrye.mutiny.vertx.MultiReadStream v;
java.util.function.Function v;
v := @parameter: io.vertx.core.streams.ReadStream;
v = new io.smallrye.mutiny.vertx.MultiReadStream;
v = staticinvoke <java.util.function.Function: java.util.function.Function identity()>();
specialinvoke v.<io.smallrye.mutiny.vertx.MultiReadStream: void <init>(io.vertx.core.streams.ReadStream,java.util.function.Function)>(v, v);
return v;
}
}