Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for doRecv (0.07 sec)

  1. internal/pubsub/pubsub_test.go

    	ch2 := make(chan Maskable, 1)
    	ch3 := make(chan Maskable, 1)
    	doneCh := make(chan struct{})
    	defer close(doneCh)
    	if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch3, doneCh, nil); err == nil {
    		t.Fatalf("unexpected nil err")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/store/store.go

    func StreamItems[I any](store Store[I], target Target, doneCh <-chan struct{}, logger logger) {
    	go func() {
    		keyCh := replayItems(store, doneCh, logger, target.Name())
    		sendItems(target, keyCh, doneCh, logger)
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. internal/pubsub/pubsub.go

    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-doneCh:
    				return
    			case v, ok := <-subChT:
    				if !ok {
    					return
    				}
    				buf.Reset()
    				err := enc.Encode(v)
    				if err != nil {
    					return
    				}
    
    				select {
    				case subCh <- append(GetByteBuffer()[:0], buf.Bytes()...):
    					continue
    				case <-doneCh:
    					return
    				}
    			}
    		}
    	}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    				}
    				return
    			}
    		}
    	}()
    	return func(err error) {
    		if doneCh == nil {
    			return
    		}
    
    		// Indicate we are ready to write.
    		doneCh <- err
    
    		// Wait for channel to be closed so we don't race on writes.
    		<-doneCh
    
    		// Clear so we can be called multiple times without crashing.
    		doneCh = nil
    	}, &closeNotifier{rc: r.Body, done: bodyDoneCh}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  5. docs/de/docs/advanced/settings.md

    /// tip | "Tipp"
    
    Damit das funktioniert, müssen Sie `pip install python-dotenv` ausführen.
    
    ///
    
    ### Die `.env`-Datei
    
    Sie könnten eine `.env`-Datei haben, mit:
    
    ```bash
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  6. docs/en/docs/advanced/settings.md

    /// tip
    
    For this to work, you need to `pip install python-dotenv`.
    
    ///
    
    ### The `.env` file
    
    You could have a `.env` file with:
    
    ```bash
    ADMIN_EMAIL="******@****.***"
    APP_NAME="ChimichangApp"
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. internal/grid/stream.go

    		}
    
    		if !done {
    			// Drain channel.
    			for range s.responses {
    			}
    		}
    	}()
    	doneCh := s.ctx.Done()
    	for {
    		select {
    		case <-doneCh:
    			if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) {
    				return err
    			}
    			// Fall through to be sure we have returned all responses.
    			doneCh = nil
    		case resp, ok := <-s.responses:
    			if !ok {
    				done = true
    				return nil
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. docs/zh/docs/advanced/settings.md

    这种做法相当常见,有一个名称,这些环境变量通常放在一个名为 `.env` 的文件中,该文件被称为“dotenv”。
    
    /// tip
    
    以点 (`.`) 开头的文件是 Unix-like 系统(如 Linux 和 macOS)中的隐藏文件。
    
    但是,dotenv 文件实际上不一定要具有确切的文件名。
    
    ///
    
    Pydantic 支持使用外部库从这些类型的文件中读取。您可以在<a href="https://docs.pydantic.dev/latest/concepts/pydantic_settings/#dotenv-env-support" class="external-link" target="_blank">Pydantic 设置: Dotenv (.env) 支持</a>中阅读更多相关信息。
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  9. cmd/consolelogger.go

    			entry := lastN[(cnt+i)%last]
    			if (entry == log.Info{}) {
    				continue
    			}
    			select {
    			case subCh <- entry:
    			case <-doneCh:
    				return nil
    			}
    		}
    	}
    	return sys.pubsub.Subscribe(madmin.LogMaskAll, subCh, doneCh, filter)
    }
    
    // Init if HTTPConsoleLoggerSys is valid, always returns nil right now
    func (sys *HTTPConsoleLoggerSys) Init(_ context.Context) error {
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. docs/pt/docs/advanced/settings.md

    /// dica
    
    Para que isso funcione você precisa executar `pip install python-dotenv`.
    
    ///
    
    ### O arquivo `.env`
    
    Você pode definir um arquivo `.env` com o seguinte conteúdo:
    
    ```bash
    ADMIN_EMAIL="******@****.***"
    APP_NAME="ChimichangApp"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 17K bytes
    - Viewed (0)
Back to top