fork download

copy

public class ChatSocketHandler implements WebSocketHandler {
 
    Sinks.Many<Event> sink = Sinks.many().multicast().onBackpressureBuffer(Queues.SMALL_BUFFER_SIZE, false);
    Flux<Event> outputMessages = sink.asFlux().cache(25);
    ObjectMapper mapper;
    Flux<String> output = Flux.from(outputMessages).map(this::toJson);
 
 
    public ChatSocketHandler(ObjectMapper objectMapper) {
        this.mapper = new ObjectMapper();
    }
 
    @Override
    public Mono<Void> handle(WebSocketSession session) {
        session.receive()
            .map(WebSocketMessage::getPayloadAsText)
            .map(this::toEvent)
            .subscribe(
                event -> sink.tryEmitNext(event),
                throwable -> sink.tryEmitError(throwable)
            );
 
        return session.send(
            Mono.delay(Duration.ofMillis(100))
                .thenMany(output.map(session::textMessage))
                .log()
        );
    }
 
    Event toEvent(String json) {
        try {
            return mapper.readValue(json, Event.class);
        } catch (IOException e) {
            throw new RuntimeException("Invalid JSON:" + json, e);
        }
    }
 
    String toJson(Event event) {
        try {
            return mapper.writeValueAsString(event);
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }
    }
}
 

Main.java:1: error: class ChatSocketHandler is public, should be declared in a file named ChatSocketHandler.java
public class ChatSocketHandler implements WebSocketHandler {
       ^
Main.java:1: error: cannot find symbol
public class ChatSocketHandler implements WebSocketHandler {
                                          ^
  symbol: class WebSocketHandler
Main.java:3: error: package Sinks does not exist
    Sinks.Many<Event> sink = Sinks.many().multicast().onBackpressureBuffer(Queues.SMALL_BUFFER_SIZE, false);
         ^
Main.java:3: error: cannot find symbol
    Sinks.Many<Event> sink = Sinks.many().multicast().onBackpressureBuffer(Queues.SMALL_BUFFER_SIZE, false);
               ^
  symbol:   class Event
  location: class ChatSocketHandler
Main.java:4: error: cannot find symbol
    Flux<Event> outputMessages = sink.asFlux().cache(25);
    ^
  symbol:   class Flux
  location: class ChatSocketHandler
Main.java:4: error: cannot find symbol
    Flux<Event> outputMessages = sink.asFlux().cache(25);
         ^
  symbol:   class Event
  location: class ChatSocketHandler
Main.java:5: error: cannot find symbol
    ObjectMapper mapper;
    ^
  symbol:   class ObjectMapper
  location: class ChatSocketHandler
Main.java:6: error: cannot find symbol
    Flux<String> output = Flux.from(outputMessages).map(this::toJson);
    ^
  symbol:   class Flux
  location: class ChatSocketHandler
Main.java:9: error: cannot find symbol
    public ChatSocketHandler(ObjectMapper objectMapper) {
                             ^
  symbol:   class ObjectMapper
  location: class ChatSocketHandler
Main.java:14: error: cannot find symbol
    public Mono<Void> handle(WebSocketSession session) {
                             ^
  symbol:   class WebSocketSession
  location: class ChatSocketHandler
Main.java:14: error: cannot find symbol
    public Mono<Void> handle(WebSocketSession session) {
           ^
  symbol:   class Mono
  location: class ChatSocketHandler
Main.java:30: error: cannot find symbol
    Event toEvent(String json) {
    ^
  symbol:   class Event
  location: class ChatSocketHandler
Main.java:38: error: cannot find symbol
    String toJson(Event event) {
                  ^
  symbol:   class Event
  location: class ChatSocketHandler
Main.java:3: error: cannot find symbol
    Sinks.Many<Event> sink = Sinks.many().multicast().onBackpressureBuffer(Queues.SMALL_BUFFER_SIZE, false);
                                                                           ^
  symbol:   variable Queues
  location: class ChatSocketHandler
Main.java:3: error: cannot find symbol
    Sinks.Many<Event> sink = Sinks.many().multicast().onBackpressureBuffer(Queues.SMALL_BUFFER_SIZE, false);
                             ^
  symbol:   variable Sinks
  location: class ChatSocketHandler
Main.java:6: error: cannot find symbol
    Flux<String> output = Flux.from(outputMessages).map(this::toJson);
                          ^
  symbol:   variable Flux
  location: class ChatSocketHandler
Main.java:10: error: cannot find symbol
        this.mapper = new ObjectMapper();
                          ^
  symbol:   class ObjectMapper
  location: class ChatSocketHandler
Main.java:13: error: method does not override or implement a method from a supertype
    @Override
    ^
Main.java:16: error: cannot find symbol
            .map(WebSocketMessage::getPayloadAsText)
                 ^
  symbol:   variable WebSocketMessage
  location: class ChatSocketHandler
Main.java:24: error: cannot find symbol
            Mono.delay(Duration.ofMillis(100))
            ^
  symbol:   variable Mono
  location: class ChatSocketHandler
Main.java:24: error: cannot find symbol
            Mono.delay(Duration.ofMillis(100))
                       ^
  symbol:   variable Duration
  location: class ChatSocketHandler
Main.java:32: error: cannot find symbol
            return mapper.readValue(json, Event.class);
                                          ^
  symbol:   class Event
  location: class ChatSocketHandler
Main.java:33: error: cannot find symbol
        } catch (IOException e) {
                 ^
  symbol:   class IOException
  location: class ChatSocketHandler
Main.java:41: error: cannot find symbol
        } catch (JsonProcessingException e) {
                 ^
  symbol:   class JsonProcessingException
  location: class ChatSocketHandler
24 errors

Standard output is empty