代码拉取完成,页面将自动刷新
// Copyright 2013-2018 The NATS Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package graft
// ChanHandler is a convenience handler when a user wants to simply use
// channels for the async handling of errors and state changes.
type ChanHandler struct {
StateMachineHandler
// Chan to receive state changes.
stateChangeChan chan<- StateChange
// Chan to receive errors.
errorChan chan<- error
}
// StateChange captures "from" and "to" States for the ChanHandler.
type StateChange struct {
// From is the previous state.
From State
// To is the new state.
To State
}
// NewChanHandler returns a Handler implementation which uses channels for
// handling errors and state changes.
func NewChanHandler(scCh chan<- StateChange, errCh chan<- error) *ChanHandler {
return NewChanHandlerWithStateMachine(new(defaultStateMachineHandler), scCh, errCh)
}
// NewChanHandlerWithStateMachine returns a Handler implementation which uses
// channels for handling errors and state changes and a StateMachineHandler for
// hooking into external state. The external state machine influences leader
// election votes.
func NewChanHandlerWithStateMachine(
stateHandler StateMachineHandler,
scCh chan<- StateChange,
errCh chan<- error) *ChanHandler {
return &ChanHandler{
StateMachineHandler: stateHandler,
stateChangeChan: scCh,
errorChan: errCh,
}
}
// Queue the state change onto the channel
func (chand *ChanHandler) StateChange(from, to State) {
chand.stateChangeChan <- StateChange{From: from, To: to}
}
// Queue the error onto the channel
func (chand *ChanHandler) AsyncError(err error) {
chand.errorChan <- err
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。