utils-shell/peco.peco
1
0
Fork 0
mirror of https://github.com/peco/peco.git synced 2026-09-10 07:16:29 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

remove unused

Browse source
This commit is contained in:
Daisuke Maki 2026-02-17 18:54:39 +09:00
parent 5fe676efb6
commit 055b7c3bbc
2 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
hub/hub.go
View file

@ -26,9 +26,9 @@ func (p *Payload[T]) Data() T {
return p.data
}
// Done marks the request as done. If Hub is operating in
// asynchronous mode (default), it's a no op. Otherwise it
// closes the reply channel to finish up the synchronous communication.
// Done marks the request as done. In non-batch mode it's a no-op.
// In batch mode it signals the sender that the receiver has finished
// processing this payload.
func (p *Payload[T]) Done() {
if p.done == nil {
return
@ -39,7 +39,6 @@ func (p *Payload[T]) Done() {
// New creates a new Hub struct
func New(bufsiz int) *Hub {
return &Hub{
isSync: false,
queryCh: make(chan *Payload[string], bufsiz),
drawCh: make(chan *Payload[*DrawOptions], bufsiz),
statusMsgCh: make(chan *Payload[StatusMsg], bufsiz),

1
hub/interface.go
View file

@ -6,7 +6,6 @@ import "sync"
// it controls how the communication that goes through channels
// are handled.
type Hub struct {
isSync bool
mutex sync.Mutex
queryCh chan *Payload[string]
drawCh chan *Payload[*DrawOptions]