//package cn.flightfeather.supervision.lightshare.repository
|
//
|
//import cn.flightfeather.supervision.domain.ds1.entity.TaskVo
|
//import cn.flightfeather.supervision.lightshare.service.TaskService
|
//import org.springframework.stereotype.Service
|
//import org.springframework.web.reactive.function.server.ServerRequest
|
//import reactor.core.publisher.Flux
|
//import reactor.core.publisher.FluxSink
|
//import reactor.core.publisher.Mono
|
//import reactor.core.publisher.MonoSink
|
//
|
//
|
//@Service
|
//class TaskRepository(val taskService: TaskService) {
|
// fun findOne(id: String) = Mono.create { sink: MonoSink<TaskVo> ->
|
// taskService.findOne(id)
|
// }
|
//
|
// fun findAll() = Flux.create { sink: FluxSink<TaskVo> ->
|
// taskService.findAll().forEach({ sink.next(it) })
|
// sink.complete()
|
// }
|
//
|
// fun save(task: TaskVo) = Mono.create { sink: MonoSink<Int> ->
|
// sink.success(333)
|
// }
|
//
|
// fun test(request: ServerRequest) = Mono.create { sink: MonoSink<Int> ->
|
// val task = request.bodyToMono(String::class.java)
|
// println(task)
|
// sink.success(333)
|
// }
|
//
|
// fun update(task: TaskVo) = Mono.create { sink: MonoSink<Int> ->
|
// sink.success(taskService.update(task))
|
// }
|
//
|
// fun delete(id: String) = Mono.create { sink: MonoSink<Int> ->
|
// sink.success(taskService.delete(id))
|
// }
|
//}
|
