INNER CODE UNIT · Go

func

aleibovici/cryptopump · algorithms/algorithms.go:27

func (c Channel) Stop(
	channel chan struct{},
	wg *sync.WaitGroup,
	configData *types.Config,
	sessionData *types.Session) {

	logger.LogEntry{ /* Log Entry */
		Config:   configData,
		Market:   nil,
		Session:  sessionData,
		Order:    &types.Order{},
		Message:  "Stopping Websocket channel" + c.name,
		LogLevel: "DebugLevel",
	}.Do()

	defer wg.Done()       /* Decrease waiting group upon completion */
	channel <- struct{}{} /* Stop websocket channel */

View source record →