//package org.egl_cepgl.pm.repository;
//
//import org.bson.types.ObjectId;
//import org.egl_cepgl.pm.model.ChatInbox;
//import org.egl_cepgl.pm.model.ChatMessage;
//import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
//import org.springframework.data.mongodb.repository.Tailable;
//import org.springframework.stereotype.Repository;
//import reactor.core.publisher.Flux;
//import reactor.core.publisher.Mono;
//
//@Repository
//public interface ChatInboxRepository extends ReactiveMongoRepository<ChatInbox, String>
//{
//    @Tailable
//    Flux<ChatInbox> findAllBy();
//
//    @Tailable
//    Flux<ChatInbox> findAllByUsername1IsOrAndUsername2Is(String userName);
//
//    Mono<Boolean> existsByNamepOrNamep(String namep1, String namep2);
//
//    Mono<ChatInbox> findByNamepOrNamep(String namep1, String namep2);
//
//    @Tailable
//    Flux<ChatInbox> findByUsername1OrUsername2(String userEmail);
//}