package fr.epita.assistants;

import io.smallrye.reactive.messaging.annotations.Broadcast;
import jakarta.inject.Inject;
import jakarta.ws.rs.Consumes;
import jakarta.ws.rs.POST;
import jakarta.ws.rs.Path;
import org.eclipse.microprofile.reactive.messaging.Channel;
import org.eclipse.microprofile.reactive.messaging.Emitter;

import java.util.concurrent.CompletionStage;

@Path("/send")
@Consumes
public class StringInfoResource {
    @Inject
    @Broadcast
    @Channel("string-info-command")
    Emitter<String> commandEmitter;

    @POST
    public void send(String s) {
        CompletionStage<Void> v = commandEmitter.send(s);
    }
}