client, err := mongo.NewClient()
if err != nil {
   return
}

err = client.Connect(context.Background())
if err != nil {
   return
}
s, err := client.StartSession()
if err != nil {
   return
}
_, err = s.WithTransaction(context.Background(), func(ctx mongo.SessionContext) (interface{}, error) {
   c, cancel := context.WithTimeout(ctx, time.Nanosecond)
   defer cancel()

   // infinite loop
   _, err = client.Database("xxx").
      Collection("xxx").
      InsertOne(c, nil)
   if err != nil {
      return nil, err
   }

   return nil, nil
})
if err != nil {
   return
}

connection(xxxx) failed to write: context deadline exceeded

for {
   err = s.StartTransaction(opts...)
   if err != nil {
      return nil, err
   }

   res, err := fn(NewSessionContext(ctx, s))
   if err != nil {
      if s.clientSession.TransactionRunning() {
         // Wrap the user-provided Context in a new one that behaves like context.Background() for deadlines and
         // cancellations, but forwards Value requests to the original one.
         _ = s.AbortTransaction(internal.NewBackgroundContext(ctx))
      }

      select {
      case <-timeout.C:
         return nil, err
      default:
      }

      if errorHasLabel(err, driver.TransientTransactionError) {
         continue
      }
      return res, err
   }
}