Commit a3a4cf97 authored by Dmitry Shipenok's avatar Dmitry Shipenok
Browse files

Added default muxer in case when none was provided.

Should fix 'echo' example.
parent 7db6e54f
...@@ -180,13 +180,19 @@ func newWithCfg(ctx context.Context, cfg *Config) (host.Host, error) { ...@@ -180,13 +180,19 @@ func newWithCfg(ctx context.Context, cfg *Config) (host.Host, error) {
ps = pstore.NewPeerstore() ps = pstore.NewPeerstore()
} }
// Set default muxer if none was passed in
muxer := cfg.Muxer
if muxer == nil {
muxer = DefaultMuxer()
}
// If secio is disabled, don't add our private key to the peerstore // If secio is disabled, don't add our private key to the peerstore
if !cfg.DisableSecio { if !cfg.DisableSecio {
ps.AddPrivKey(pid, cfg.PeerKey) ps.AddPrivKey(pid, cfg.PeerKey)
ps.AddPubKey(pid, cfg.PeerKey.GetPublic()) ps.AddPubKey(pid, cfg.PeerKey.GetPublic())
} }
swrm, err := swarm.NewSwarmWithProtector(ctx, cfg.ListenAddrs, pid, ps, cfg.Protector, cfg.Muxer, cfg.Reporter) swrm, err := swarm.NewSwarmWithProtector(ctx, cfg.ListenAddrs, pid, ps, cfg.Protector, muxer, cfg.Reporter)
if err != nil { if err != nil {
return nil, err return nil, err
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment