Code explainers tagged #streaming

import random
from typing import Iterator, List
 
 

const express = require('express');
const router = express.Router();
 
router.get('/exports/orders', async (req, res) => {

const fs = require('fs');
const path = require('path');
const express = require('express');
 

public final class ChunkSorter {
 
    private static final int MAX_LINES_PER_CHUNK = 100_000;
 

func StreamLogs(c *gin.Context) {
	path := c.Query("file")
	if path == "" {
		c.JSON(http.StatusBadRequest, gin.H{"error": "missing file parameter"})

<?php
 
function streamFileWithRanges(string $path, ?string $rangeHeader): void
{

import os
import re
from flask import Blueprint, request, Response, abort
 

func ServeThumbnail(c *gin.Context) {
	raw := c.Param("token")
	sig := c.Query("sig")
 

import OpenAI from 'openai';
 
const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY });
 

func (h *ReportHandler) ExportTransactions(w http.ResponseWriter, r *http.Request) {
	ctx := r.Context()
 
	from, to, err := parseDateRange(r.URL.Query())

use axum::{
    body::Body,
    extract::State,
    http::{header, StatusCode},

import heapq
 
 
class MovingMedian:

interface RunningStats {
  count: number;
  total: number;
  average: number;

package logparse
 
import (
	"bufio"

import hashlib
from collections import defaultdict
from pathlib import Path
 

import { NextResponse } from 'next/server';
import { db } from '@/lib/db';
 
function csvCell(value) {

class MovingAverage {
  constructor(windowSize) {
    if (!Number.isInteger(windowSize) || windowSize <= 0) {
      throw new RangeError('windowSize must be a positive integer');

import { Suspense } from 'react';
import { searchProducts } from '@/lib/products';
import SearchInput from './search-input';